package com.jy.oms.framework.asyn.task.queue.database.dao;

import com.jy.oms.framework.asyn.task.core.MapperAndDAO;
import com.jy.oms.framework.asyn.task.queue.database.entity.SysTaskQuery;
import com.jy.oms.framework.asyn.task.queue.database.entity.SysTaskQueue;
import org.apache.ibatis.annotations.Param;

import java.util.List;

@MapperAndDAO
public interface SysTaskQueueDao {

    int querySysTaskCount(@Param("param") SysTaskQuery sysTaskQuery, @Param("taskQueueName") String taskQueueName);

    List<SysTaskQueue> querySysTaskList(@Param("param") SysTaskQuery param, @Param("taskQueueName") String taskQueueName);

    int insertSysTask(@Param("param") SysTaskQueue sysTask, @Param("taskQueueName") String taskQueueName);

    int insertSysTaskList(@Param("list") List<SysTaskQueue> sysTasks, @Param("taskQueueName") String taskQueueName);

    int updateById(@Param("param") SysTaskQueue sysTask, @Param("taskQueueName") String taskQueueName);

    int updateBatchById(@Param("list") List<SysTaskQueue> sysTasks, @Param("taskQueueName") String taskQueueName);
}